// module.exports = options => {
//   return async (ctx,next) => {
//     try {
//       ctx.logger.info(ctx.req.msg)
//       // ctx.req.message = JSON.parse(ctx.req.msg)
//     }catch (e) {
//       ctx.logger.error(e)
//     }
//     await next();
//     ctx.logger.info(`响应时间: ${ctx.starttime ? Date.now() - ctx.starttime : 0}ms Topic：${ctx.req.topic} Msg: ${ctx.req.msg}`);
//   }
// }